package com.alibaba.otter.node.etl.load.loader.mq.rabbit.exception;

import com.alibaba.otter.node.etl.load.loader.mq.rabbit.model.MessageContext;
import lombok.Getter;

public class MqConsumeException extends MqPluginException {

    @Getter
    private MessageContext msgCtx;
    @Getter
    private Throwable origin;

    public MqConsumeException(String message, MessageContext masCtx) {
        super(message);
        this.msgCtx = masCtx;
    }

    public MqConsumeException(String message, MessageContext msgCtx, Throwable cause) {
        super(message, cause);
        this.msgCtx = msgCtx;
        this.origin = cause;
    }
}
